const express = require('express');
const app = express();
const http = require('http');
const server = http.createServer(app);
const { Server } = require("socket.io");
const io = new Server(server, {
  cors: {
    origin: '*'
  }
});

// 调用io.on()方法，监听客户端向socket.io服务端发起的websocket连接请求
// 一旦有客户端试图连接当前服务，将立即监听到该动作
// 连接建立成功后执行回调方法    socket就是websocket连接对象

io.on('connection', (socket) => {
  console.log('有客户端进来了！'+socket.id); 
  
  // 监听接收消息 textmsg
  socket.on('textmsg', function(data){
    // console.log('客户端说：' + data)
    io.emit('textmsg',data)
  })
  socket.on('textmsg2',function(data){
    io.emit('textmsg2',data)
  })
});

server.listen(5000, () => {
  console.log('listening on *:5000');
});